package org.lyj.samples;

import io.vertx.core.Vertx;

public class Main {

    public static void main(String[] args) throws InterruptedException {
        Vertx vertx = Vertx.vertx();
        vertx.eventBus().registerCodec(CustomizeMessageCodec.create());//注册编码器
        vertx.deployVerticle(new DownloadVerticle());
        vertx.deployVerticle(new EventBusReceiverVerticle("R1"));
        vertx.deployVerticle(new EventBusReceiverVerticle("R2"));
        Thread.sleep(1000);
        vertx.deployVerticle(new EventBusSenderVerticle("hello"));
    }
}
